package dj.thread;

import dj.Constant;
import dj.service.TalkContextService;

public class TalkContextThread implements Runnable {

	private TalkContextService tcs = (TalkContextService) Constant.ac.getBean("talkContextService");

	public void run() {

		while(true) {
			tcs.updateContextIsread();
			
			try {
				//间隔30秒 存一次用户消息
				Thread.sleep(30 * 1000);
			} catch (InterruptedException e) {
				continue;
			}
		}
	}
}
